# !/bin/bash

# 获取处理数据日期 如果传递直接赋值，否则提前一天
if [ -n "$1" ] ; then
  data_date=$1
else
  data_date=$(date -d "-1 days" +%F)
fi

# 将Mysql中地理表同步到hdfs
/opt/module/sqoop/bin/sqoop import \
--connect  jdbc:mysql://node101:3306/jtp_app_shujuku \
--username root \
--password 123456 \
--as-textfile \
--query 'SELECT ID, AREANAME, PARENTID, SHORTNAME, LEVEL, FLAG, WGS84_LNG, WGS84_LAT, GCJ02_LNG, GCJ02_LAT, BD09_LNG, BD09_LAT FROM jtp_app_shujuku.t_md_areas WHERE $CONDITIONS AND 1=1;' \
--delete-target-dir \
--target-dir "hdfs://node101:8020/warehouse/app_basic/t_md_areas/${data_date}" \
--num-mappers 1 \
--fields-terminated-by '\001' \
--null-string '\\N' \
--null-non-string '\\N'
